package com.gitee.zhanyao.codebase.java.rocketmq.config;

import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@EnableBinding({MySource.class, MySink.class})
@Configuration
public class RocketMqConfig {

    @Bean
    public CustomRunner customRunner() {
        return new CustomRunner("output1");
    }

    @Bean
    public CustomRunner customRunner2() {
        return new CustomRunner("output3");
    }

    @Bean
    public CustomRunnerWithTransactional customRunnerWithTransactional() {
        return new CustomRunnerWithTransactional();
    }

    @Bean
    public ConsumerCustomRunner consumerCustomRunner() {
        return new ConsumerCustomRunner();
    }

}
